package com.minimalist.common.config.rocketmq.producer;

/**
 * @author 11987
 */
//@Service
//public class RocketMqProducer{
//    private static final Logger log = LoggerFactory.getLogger(RocketMqProducer.class);
//
//    @Autowired
//    private RocketMQTemplate rocketMqTemplate;
//
//    private final String topic = "TestTopic";
//
//    public void sendSyncMessage(String message){
//        SendResult sendResult = rocketMqTemplate.syncSend(topic
//                , MessageBuilder.withPayload(message).build());
//        log.info("同步发送结果: {} {}", message, sendResult);
//    }
//
//    public void sendAsyncMessage(String message){
//        rocketMqTemplate.asyncSend(topic, MessageBuilder.withPayload(message).build()
//                , new SendCallback(){
//
//                    @Override
//                    public void onSuccess(SendResult sendResult){
//                        log.info("异步发送成功: {} {}", message, sendResult);
//                    }
//
//                    @Override
//                    public void onException(Throwable throwable){
//                        log.error("异步发送失败:{} {}", message, throwable.getMessage());
//                    }
//                });
//    }
//
//    public void sendOneWayMessage(String message){
//        rocketMqTemplate.sendOneWay(topic, MessageBuilder.withPayload(message).build());
//        log.info("单向消息发送成功: {}", message);
//    }
//
//    public void sendDelayMessage(String message, int delayTime){
//        SendResult sendResult = rocketMqTemplate.syncSendDelayTimeSeconds(topic
//                , MessageBuilder.withPayload(message).build(), delayTime);
//        log.info("延时消息发送结果: {} {}", message, sendResult);
//    }
//}


